package com.project.MessageRoute.executor;

public interface PushConsumer {

    void subscribe(String topic, String subExpression);
    void start();
    void close();

}
